package com.atguigu.webflux.reactor8;

import java.util.Observable;

public class ObserverDemo extends Observable {

    public static void main(String[] args) {

        ObserverDemo observerDemo = new ObserverDemo();
        observerDemo.addObserver((o,arg) ->{
            System.out.println("发生变化");
        });

        observerDemo.addObserver((o,arg) ->{
            System.out.println("收到被观察者通知，准备改变");
        });

        observerDemo.setChanged();
        observerDemo.notifyObservers();
    }
}
